<?php

namespace App\Process;

use App\Event\Event;
use EasySwoole\Component\Process\AbstractProcess;
use EasySwoole\EasySwoole\Logger;
use EasySwoole\Queue\Job;

class LmtProcess extends AbstractProcess
{
    protected function run($arg)
    {
        //必须重启服务调试进程开启后常驻内存
        go(function (){
            LmtQueue::getInstance()->consumer()->listen(function (Job $job){
                LmtQueue::getInstance()->responseExecutionResult($job);
/*                if(Event::getInstance()->hook($data['event'], $data['args'])) {
                    LmtQueue::getInstance()->consumer()->confirm($job);
                }*/

            });
        });
    }
}
